package com.ahaoyou.canal;

import com.ahaoyou.entity.User;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;
import java.util.List;

@Data
@AllArgsConstructor
@NoArgsConstructor
public class CanalBean implements Serializable {
    /**
     * 数据
     */
    private List<User> data;
    /**
     *  数据库名称
     */
    private String database;
    private long es;
    /**
     * id
     */
    private int id;

    private boolean isDdl;

    private MysqlType mysqlType;

    private List<User> old;
    /**
     * 数据表主键
     */
    private List<String> pkNames;
    /**
     * sql语句
     */
    private String sql;
    /**
     *
     */
    private SqlType sqlType;

    /**
     * 表名
     */
    private String table;
    private long ts;
    /**
     *   (新增)INSERT、(更新)UPDATE、(删除)DELETE、(删除表)ERASE等等
     */
    private String type;
}